package com.jdbc_.Apache_Druid;

import com.jdbc_.datasource.JDBCUtilsByDruid;
import org.apache.commons.dbutils.QueryRunner;
import org.junit.jupiter.api.Test;

import java.sql.Connection;
import java.sql.SQLException;

// Apache + Druid 完成增删改查
public class Demo_DML {
    @Test
    public void testDML() throws SQLException {
        // 1、获取连接
        Connection connection = JDBCUtilsByDruid.getConnection();
        // 2、创建QueryRunner对象
        QueryRunner queryRunner = new QueryRunner();
        // 3、就可以执行sql了
        String sql = "update actor set name=? where id=?";
        // 这时，要改变方法为update(Connection connection, String sql, Object... param)
        // 【注意】：update()方法也可以执行insert、delete语句
        // 返回的是受影响的行数
        int affectedRows = queryRunner.update(connection, sql, "Jack", 1);

        System.out.println(affectedRows > 0 ? "执行成功" : "执行没有影响到表");

        // 4、关闭连接
        JDBCUtilsByDruid.close(null, null, connection);
    }
}
